package com.bfxy.esjob.task;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

//import com.moss.rabbit.task.annotation.ElasticJobConfig;
import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;

//@ElasticJobConfig
//@Component
public class MySimpleJob implements SimpleJob {


    //	@JobTrace
    @Override
    public void execute(ShardingContext shardingContext) {

        System.err.println("---------	开始任务 MySimpleJob	" + shardingContext.getShardingParameter() + "---------");
//		
//		System.err.println(shardingContext.getJobName());
//		System.err.println(shardingContext.getJobParameter());
//		System.err.println(shardingContext.getShardingItem());
//		System.err.println(shardingContext.getShardingParameter());
//		System.err.println(shardingContext.getShardingTotalCount());
//		System.err.println("当前线程 : ---------------" + Thread.currentThread().getName());
//		
//		System.err.println("----------结束任务------");
    }


}